let fs = require('fs')
let EventEmitter = require('events').EventEmitter;

let fileArray = [];
let event = new EventEmitter();

fs.readdir(__dirname + '/dirtyData/', (err, files) => {
    if (err) {
        return console.error(err);
    }
    fileArray = files;
    event.emit('readFinsh');
})

event.on('readFinsh', () => {
    if (fs.existsSync(__dirname + "/cleanData")) {
        fs.rmSync(__dirname + '/cleanData', { "recursive": true });
    }
    fs.mkdirSync(__dirname + '/cleanData');
    fileArray.forEach((value, index) => {
        let lag = index;
        fs.readFile(__dirname + '/dirtyData/' + value, (err, data) => {
            if (err) {
                return console.error(err);
            }
            let dirtyData = JSON.parse(data.toString());
            dirtyData.body.forEach(value => {
                fs.writeFile(__dirname + '/cleanData/' + `clean${lag}.txt`, `\r\n${value.content}`, { 'flag': "a+" }, () => {
                    if (err) {
                        return console.error(err);
                    }
                })
            })
        })
    })
})



